package com.ext.springcloud.handler.order;

import com.ext.springcloud.channel.order.OrderSetChannel;
import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.stereotype.Component;

/**
 * @FileName: OrderSetConsumer
 * @Author: <a href="dongann@aliyun.com">dongchang'an</a>.
 * @CreateTime: 2021/8/12 17:49
 * @Version: v1.0
 * @description:
 */
@EnableBinding(value = {OrderSetChannel.class})
@Slf4j
@Component
public class OrderSetConsumer {

    @StreamListener(value = OrderSetChannel.SET_ORDER_INPUT)
    public void process(String orderMsg){
        log.info("订单下单成功消息消费:{}",orderMsg);
    }
}
